package com.tarena.rocketmq.study;

import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;
import org.junit.Test;

import java.nio.charset.StandardCharsets;

public class MyProducer {
    @Test
    public void send() throws Exception{
        //1. 连接nameserver生产者对象
        DefaultMQProducer producer = new DefaultMQProducer();
        producer.setNamesrvAddr("localhost:9876");
        //生产者 和消费者 都是集群结构
        producer.setProducerGroup("test-producer01");
        //生产者可以启动了.
        producer.start();
        //2. 组织创建一个消息
        //创建一个消息对象
        Message message=new Message();
        //消息数据 message body
        String msgTxt="你好呀,这是第一条消息";
        message.setBody(msgTxt.getBytes(StandardCharsets.UTF_8));
        //提供一个主题名称,在消息中间件中保存消息的目的地 当前消息队列没有主题名称 但是代码可以自动创建
        message.setTopic("test-01-topic");
        //3. 将消息发送
        SendResult send = producer.send(message);
        System.out.println(send.getSendStatus());//表示发送的状态
        while(true);

    }
}
